00f1014873a10ca800f6c9efdfdb12a82a09c8ee,components/camel-cassandraql/src/main/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationRepository.java,CassandraAggregationRepository,initSelectKeyIdStatement,#,274

Before Change



    // -------------------------------------------------------------------------
    private void initSelectKeyIdStatement() {
        String cql = generateSelect(table,
                new String[]{getKeyColumn(), exchangeIdColumn}, // Key + Exchange Id columns
                pkColumns, pkColumns.length - 1).toString(); // Where fixed PK columns
        LOGGER.debug("Generated Select keys {}", cql);
        selectKeyIdStatement = applyConsistencyLevel(getSession().prepare(cql), readConsistencyLevel);
    }

    protected List<Row> selectKeyIds() {

After Change



    // -------------------------------------------------------------------------
    private void initSelectKeyIdStatement() {
        Select select = generateSelect(table,
                new String[]{getKeyColumn(), exchangeIdColumn}, // Key + Exchange Id columns
                pkColumns, pkColumns.length - 1); // Where fixed PK columns
        select = applyConsistencyLevel(select, readConsistencyLevel);
        LOGGER.debug("Generated Select keys {}", select);
        selectKeyIdStatement = getSession().prepare(select);
    }

    protected List<Row> selectKeyIds() {